package org.netty.server.config;

import org.netty.server.handler.NettyServerDecoder;
import org.netty.server.handler.NettyServerEncoder;
import org.netty.server.handler.NettyServerHandler;
import org.netty.server.handler.NettyServerOutHandler;

import io.netty.channel.ChannelInitializer;
import io.netty.channel.socket.SocketChannel;

public class CustomizeChannelInit extends ChannelInitializer<SocketChannel> {

    @Override
    protected void initChannel(SocketChannel channel) {
        // 自定义解码器
        channel.pipeline().addLast(new NettyServerDecoder());
        // 自定义编码器
        channel.pipeline().addLast(new NettyServerEncoder());
        // 消息出站处理器
        channel.pipeline().addLast(new NettyServerOutHandler());
        // 在管道中添加我们自己的接收数据实现方法
        channel.pipeline().addLast(new NettyServerHandler());
    }

}